package cn.szv5;

/**
 * @ClassName NameNodeRpcServer
 * @Description NameNode的rpc服务接口
 * @Author Carl
 * @Company: 阿飞工作室(https : / / szv5.cn)
 * @Date 2022/3/1 20:07
 * @Version 1.0
 **/
public class NameNodeRpcServer {

    /**
     * 负责管理元数据的核心组件
     */
    private FSNamesystem fsNamesystem;

    public NameNodeRpcServer(FSNamesystem fsNamesystem) {
        this.fsNamesystem = fsNamesystem;
    }

    /**
     * 创建目录
     * @return
     * @throws Exception
     */
    public boolean mkdir(String path) throws Exception {
        return fsNamesystem.mkdir(path);
    }

    /**
     * 启动rpc server
     */
    public void start() {
        System.out.println("开始监听指定的rpc server的端口号，来接收请求");
    }
}
